package com.hzhr.iot.collect.protocol.sender;

import com.hzhr.iot.collect.model.SendMessageRtnModel;
import com.hzhr.iot.collect.util.RedisUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;

@Component
public class Sender2 implements Sender {
    @Autowired
    RedisUtil redisUtil;

    @Value("${version}")
    private String version;

    @Override
    public SendMessageRtnModel send(String message, String deviecId, Integer expireTime) throws Exception {
        String key = "socket_service:resp_command" + deviecId + ":";
        redisUtil.lPush(key, message);
        return null;
    }

}
